package base.http.rxandroid

import org.reactivestreams.Subscriber
import org.reactivestreams.Subscription

/**
 * @author njmsir
 * Created by njmsir on 2017/9/8.
 * 一个什么都没有的Subscriber,用于实现简单功能不需要把所有方法都重写,只需重写你想重写的方法
 */
abstract class NothingSubscriber<T> : Subscriber<T> {
    override fun onError(t: Throwable?) {
    }

    /**
     * 这是必须重写的方法
     */
    override abstract fun onSubscribe(s: Subscription?)

    override fun onComplete() {
    }

    override fun onNext(t: T) {
    }
}